package com.hrt.test.common;

public class MsgProducer extends Thread {

    private String name;
    private String tag;

    public MsgProducer(String name, String tag) {
        this.name = name;
        this.tag = tag;
    }

    @Override
    public void run() {
        int counter = 1;
        int maxCount = 100;

        while (counter <= maxCount) {
            MsgQueueManager.getInstance().produce(name, tag + name + counter);
            counter++;
        }
    }
}